package com.huatai.datacenter.entity.messagequeuemonitor;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.ArrayList;
import java.util.List;

/**
 * 该主题的一个消费组消费信息
 *
 * @author lizhong
 */
@ApiModel("该主题的一个消费组消费信息")
@Data
@NoArgsConstructor
public class TopicConsumerInfo {
	// 该主题
	@ApiModelProperty("该主题")
	private String topic;

	// 该消费者
	@ApiModelProperty("该消费组")
	private String group;

	// 总的堆积
	@ApiModelProperty("总的消息堆积数")
	private long diffTotal;

	// 所有队列状态信息列表，主要字段: (broker名和队列id)
	@ApiModelProperty("该主题该消费组下的所有队列")
	private List<QueueStatInfo> queueStatInfoList = new ArrayList<>();

	@ApiModelProperty("该主题该消费组对应的所有分区")
	private List<LagStatVO> lagStatVOList = new ArrayList<>();

	public TopicConsumerInfo(String topic, String group) {
		this.topic = topic;
		this.group = group;
	}
}
